// package com.hxb.example;
//
// import io.github.resilience4j.core.ContextPropagator;
// import io.seata.core.context.RootContext;
//
// import java.util.Optional;
// import java.util.function.Consumer;
// import java.util.function.Supplier;
//
// /**
//  * seata xid 传播处理
//  *
//  * @author jxh
//  * @version 1.0.0
//  * @since 2023/11/15 16:18
//  */
// public class SeataPropagator implements ContextPropagator<String> {
//
//     @Override
//     public Supplier<Optional<String>> retrieve() {
//         return () -> Optional.ofNullable(RootContext.getXID());
//     }
//
//     @Override
//     public Consumer<Optional<String>> copy() {
//         return s -> s.ifPresent(RootContext::bind);
//     }
//
//     @Override
//     public Consumer<Optional<String>> clear() {
//         return s -> RootContext.unbind();
//     }
// }
